5940b3c72cb37ed88caa961aad57cff450936e35,advanced/main/java/org/neo4j/kernel/ha/CommunicationProtocol.java,CommunicationProtocol,handleRequest,#Master#ChannelBuffer#Channel#MasterServer#,218

Before Change


        if ( type.includesSlaveContext() )
        {
            context = readSlaveContext( buffer );
            server.mapSlave( channel, context );
        }
        Response<?> response = type.caller.callMaster( realMaster, context, buffer );
        ChannelBuffer targetBuffer = ChannelBuffers.dynamicBuffer();

After Change


        {
            context = readSlaveContext( buffer );
        }
        Pair<ChannelBuffer, ByteBuffer> targetBuffers = server.mapSlave( channel, context );
        targetBuffers.first().clear();
        Response<?> response = type.caller.callMaster( realMaster, context, buffer );
        type.serializer.write( response.response(), targetBuffers.first() );
        if ( type.includesSlaveContext() )
        {
            writeTransactionStreams( response.transactions(), targetBuffers.first(), targetBuffers.other() );
        }
        if ( type == RequestType.FINISH || type == RequestType.PULL_UPDATES )
        {
            server.unmapSlave( channel, context );
        }
        return targetBuffers.first();
    }
    
    private static <T> void writeTransactionStreams( TransactionStreams txStreams,